package drds.data_propagate.common.alarm;

import drds.data_propagate.common.LifeCycle;

/**
 * canal报警处理机制
 */
public interface AlarmHandler extends LifeCycle {

    /**
     * 发送对应destination的报警
     */
    void sendAlarm(String destination, String msg);
}
